package ckR

import (
	mq "db2s/topic-mq"
)

// isModeListeners IsSegmentQuery  监听执行器
func isModeListeners(message mq.Message) mq.ConsumeConcurrentlyStatus {
	var (
		plan   = message.Properties["plan"].(*SchedulePlan2)
		dTopic = IsMode
	)
	defer deleteTopic(map[string]any{"dTopic": dTopic, "subTask": plan.subTaskInfo, "topic": string(dTopic), "outFay": GlobalPConfigs.result.Teletypewriter})
	switch GlobalPConfigs.rules.RowsR.Options {
	case "count":
		countWayListeners(message)
	}
	return mq.ConsumeSuccess
}
